let mysql = require('mysql');
let {options} = require('./config')


// 1 创建一个连接的对象
let conn = mysql.createConnection(options);
//2, 尝试连接数据库
conn.connect((err) => {
    if (err) {
        console.log('数据库连接失败', err);
        return;
    }
})
function query(sql, arr) {
    return new Promise((resolve, reject) => {
        conn.query(sql, arr, (err, result) => {
            if (!err) {
                resolve(result);// 将sql 执行返回的结果保存到promise中
            } else {
                reject(err)
            }

        })
    })
}
// 4 断开连接 释放资源
function close() {
    conn.end();
}
module.exports = {
    query,
    close
}